Java利用阿里云OSS/本地存储实现文件上传功能 |
您所在的位置:网站首页 › java读取linux文件 存储本地 › Java利用阿里云OSS/本地存储实现文件上传功能 |
目录 1、简介 2、本地存储 3、阿里云OSS 3.1、准备 3.2、入门 3.3、项目实施 3.4、注意 4、图片删除 🍃作者介绍:双非本科大三网络工程专业在读,阿里云专家博主,专注于Java领域学习,擅长web应用开发、数据结构和算法,初步涉猎Python人工智能开发和前端开发。 🦅主页:@逐梦苍穹 ✈ 所属专栏:Java Web 📕您的一键三连,是我创作的最大动力🌹 1、简介文件上传,是指将本地图片、视频、音频等文件上传到服务器,供其他用户浏览或下载的过程。 文件上传在项目中应用非常广泛,我们经常发微博、发微信朋友圈都用到了文件上传功能。 想要完成文件上传这个功能需要涉及到两个部分: 前端程序服务端程序本文着重介绍服务端程序。这里通过黑马程序员苍穹外卖项目中的"修改套餐"业务来举例说明,例子分别为本地存储和阿里云OSS存储。 2、本地存储首先看一下页面效果: 这个地方需要上传图片。 下面实现一个controller来接收图片: 加上所必须的注解(@RestController、@RequestMapping)等,然后编写upload方法。 首先是要获取到用户上传的这张图片的名称(完整名称,包括后缀),然后重新为文件起一个新的名称(这个名称的要求是需要唯一,避免机缘巧合的情况下跟本地其他图片重复),这里采用的是UUID: 然后是构造存储路径,把文件存入本地: 最后需要返回给前端图片的路径,注意:这里的路径并不是本地存储路径,而是访问路径! 构造访问路径,需要在配置类中配置映射: 这个配置类中配置映射的代码,意思是把localhost:8080/images/下面的任何资源,都对应的映射到本地的路径下面。所以返回的访问路径就应该是: 这里的127.0.0.1就是本地地址,等同于localhost 本地存储的完整代码如下: package com.sky.controller.upload; import com.sky.constant.MessageConstant; import com.sky.exception.FireNameIsNullException; import com.sky.result.Result; import com.sky.utils.AliOssUtil; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.multipart.MultipartFile; import java.io.File; import java.io.IOException; import java.util.UUID; /** * @author 逐梦苍穹 * @date 2023/10/11 8:35 */ @RestController @RequestMapping("/admin/common") @Api(tags = "文件上传(无阿里云)controller接口") @Slf4j public class UploadNoAliOssController { @Autowired private AliOssUtil aliOssUtil; /** * 文件上传接口 * * @param file * @return */ @PostMapping("/upload") @ApiOperation("文件上传") public Result upload(MultipartFile file) { log.info("文件上传:{}", file); String originalFilename = file.getOriginalFilename(); try { if (originalFilename != null) { // 利用UUID构造新的文件名称 String objectName = UUID.randomUUID().toString() + originalFilename; // 文件的请求路径 String filePath = "E:\\javaSTUDY\\sky-take-out-imageFile\\" + objectName; String returnImagePate = "http://127.0.0.1:8080/images/" + objectName; file.transferTo(new File(filePath)); return Result.success(returnImagePate); } else { throw new FireNameIsNullException(MessageConstant.FILE_NAME_IS_NULL); } } catch (IOException e) { e.printStackTrace(); log.error("文件上传失败:{}", e); } return Result.error(MessageConstant.UPLOAD_FAILED); } }到时此,我们文件上传的本地存储方式已完成了。但是这种本地存储方式还存在一问题: 如果直接存储在服务器的磁盘目录中,存在以下缺点: 不安全:磁盘如果损坏,所有的文件就会丢失容量有限:如果存储大量的图片,磁盘空间有限(磁盘不可能无限制扩容)无法直接访问为了解决上述问题呢,通常有两种解决方案: 自己搭建存储服务器,如:fastDFS 、MinIO使用现成的云服务,如:阿里云,腾讯云,华为云下面介绍阿里云OSS。 3、阿里云OSS 3.1、准备阿里云是阿里巴巴集团旗下全球领先的云计算公司,也是国内最大的云服务提供商 。 云服务指的就是通过互联网对外提供的各种各样的服务,比如像:语音服务、短信服务、邮件服务、视频直播服务、文字识别服务、对象存储服务等等。 当我们在项目开发时需要用到某个或某些服务,就不需要自己来开发了,可以直接使用阿里云提供好的这些现成服务就可以了。比如:在项目开发当中,我们要实现一个短信发送的功能,如果我们项目组自己实现,将会非常繁琐,因为你需要和各个运营商进行对接。而此时阿里云完成了和三大运营商对接,并对外提供了一个短信服务。我们项目组只需要调用阿里云提供的短信服务,就可以很方便的来发送短信了。这样就降低了我们项目的开发难度,同时也提高了项目的开发效率。(大白话:别人帮我们实现好了功能,我们只要调用即可) 云服务提供商给我们提供的软件服务通常是需要收取一部分费用的。 阿里云对象存储OSS(Object Storage Service),是一款海量、安全、低成本、高可靠的云存储服务。使用OSS,您可以通过网络随时存储和调用包括文本、图片、音频和视频等在内的各种文件。 在我们使用了阿里云OSS对象存储服务之后,我们的项目当中如果涉及到文件上传这样的业务,在前端进行文件上传并请求到服务端时,在服务器本地磁盘当中就不需要再来存储文件了。我们直接将接收到的文件上传到oss,由 oss帮我们存储和管理,同时阿里云的oss存储服务还保障了我们所存储内容的安全可靠。 而无论使用什么样的云服务,阿里云也好,腾讯云、华为云也罢,在使用第三方的服务时,操作的思路都是一样的。 SDK:Software Development Kit 的缩写,软件开发工具包,包括辅助软件开发的依赖(jar包)、代码示例等,都可以叫做SDK。 简单说,sdk中包含了我们使用第三方云服务时所需要的依赖,以及一些示例代码。我们可以参照sdk所提供的示例代码就可以完成入门程序。 接下来介绍一下当前要使用的阿里云oss对象存储服务具体的使用步骤。 Bucket:存储空间是用户用于存储对象(Object,就是文件)的容器,所有的对象都必须隶属于某个存储空间。 下面根据之前介绍的使用步骤,完成准备工作: ①注册阿里云账户(注册完成后需要实名认证) ②注册完账号之后,就可以登录阿里云 ③通过控制台找到对象存储OSS服务 如果是第一次访问,还需要开通对象存储服务OSS ④开通OSS服务之后,就可以进入到阿里云对象存储的控制台 ⑤点击左侧的 "Bucket列表",创建一个Bucket 阿里云oss 对象存储服务的准备工作已经完成了,接下来参照官方所提供的sdk示例来编写入门程序。 首先需要打开阿里云OSS的官方文档,在官方文档中找到 SDK 的示例代码: 参照官方提供的SDK,改造一下,即可实现文件上传功能: import com.aliyun.oss.ClientException; import com.aliyun.oss.OSS; import com.aliyun.oss.OSSClientBuilder; import com.aliyun.oss.OSSException; import com.aliyun.oss.model.PutObjectRequest; import com.aliyun.oss.model.PutObjectResult; import java.io.FileInputStream; import java.io.InputStream; public class AliOssTest { public static void main(String[] args) throws Exception { // Endpoint以华东1(杭州)为例,其它Region请按实际情况填写。 String endpoint = "oss-cn-shanghai.aliyuncs.com"; // 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。 String accessKeyId = ""; String accessKeySecret = ""; // 填写Bucket名称,例如examplebucket。 String bucketName = "web-framework01"; // 填写Object完整路径,完整路径中不能包含Bucket名称,例如exampledir/exampleobject.txt。 String objectName = "1.jpg"; // 填写本地文件的完整路径,例如D:\\localpath\\examplefile.txt。 // 如果未指定本地路径,则默认从示例程序所属项目对应本地路径中上传文件流。 String filePath= "C:\\Users\\Administrator\\Pictures\\1.jpg"; // 创建OSSClient实例。 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); try { InputStream inputStream = new FileInputStream(filePath); // 创建PutObjectRequest对象。 PutObjectRequest putObjectRequest = new PutObjectRequest(bucketName, objectName, inputStream); // 设置该属性可以返回response。如果不设置,则返回的response为空。 putObjectRequest.setProcess("true"); // 创建PutObject请求。 PutObjectResult result = ossClient.putObject(putObjectRequest); // 如果上传成功,则返回200。 System.out.println(result.getResponse().getStatusCode()); } catch (OSSException oe) { System.out.println("Caught an OSSException, which means your request made it to OSS, " + "but was rejected with an error response for some reason."); System.out.println("Error Message:" + oe.getErrorMessage()); System.out.println("Error Code:" + oe.getErrorCode()); System.out.println("Request ID:" + oe.getRequestId()); System.out.println("Host ID:" + oe.getHostId()); } catch (ClientException ce) { System.out.println("Caught an ClientException, which means the client encountered " + "a serious internal problem while trying to communicate with OSS, " + "such as not being able to access the network."); System.out.println("Error Message:" + ce.getMessage()); } finally { if (ossClient != null) { ossClient.shutdown(); } } } }在以上代码中,需要替换的内容为: accessKeyId:阿里云账号AccessKey accessKeySecret:阿里云账号AccessKey对应的秘钥 bucketName:Bucket名称 objectName:对象名称,在Bucket中存储的对象的名称 filePath:文件路径AccessKey : 运行以上程序后,会把本地的文件上传到阿里云OSS服务器上: 在黑马苍穹外卖项目中,配置阿里云OSS实现图片上传的步骤如下: ①编写阿里云OSS配置属性类: ②在application-dev.yml文件中定义各配置项的值: ③在application.yml中配置: ④编写工具类,工具类的核心如下: 代码: package com.sky.utils; import com.aliyun.oss.ClientException; import com.aliyun.oss.OSS; import com.aliyun.oss.OSSClientBuilder; import com.aliyun.oss.OSSException; import lombok.AllArgsConstructor; import lombok.Data; import lombok.extern.slf4j.Slf4j; import java.io.ByteArrayInputStream; /** * 阿里云OSS对象存储服务工具类 * @author 逐梦苍穹 */ @Data @AllArgsConstructor @Slf4j public class AliOssUtil { private String endpoint; private String accessKeyId; private String accessKeySecret; private String bucketName; /** * 文件上传 * * @param bytes * @param objectName * @return */ public String upload(byte[] bytes, String objectName) { // 创建OSSClient实例。 OSS ossClient = new OSSClientBuilder().build(endpoint, accessKeyId, accessKeySecret); try { // 创建PutObject请求。 ossClient.putObject(bucketName, objectName, new ByteArrayInputStream(bytes)); } catch (OSSException oe) { System.out.println("Caught an OSSException, which means your request made it to OSS, " + "but was rejected with an error response for some reason."); System.out.println("Error Message:" + oe.getErrorMessage()); System.out.println("Error Code:" + oe.getErrorCode()); System.out.println("Request ID:" + oe.getRequestId()); System.out.println("Host ID:" + oe.getHostId()); } catch (ClientException ce) { System.out.println("Caught an ClientException, which means the client encountered " + "a serious internal problem while trying to communicate with OSS, " + "such as not being able to access the network."); System.out.println("Error Message:" + ce.getMessage()); } finally { if (ossClient != null) { ossClient.shutdown(); } } //文件访问路径规则 https://BucketName.Endpoint/ObjectName StringBuilder stringBuilder = new StringBuilder("https://"); stringBuilder .append(bucketName) .append(".") .append(endpoint) .append("/") .append(objectName); log.info("文件上传到:{}", stringBuilder.toString()); return stringBuilder.toString(); } }⑤编写OSS配置类: package com.sky.config; import com.sky.properties.AliOssProperties; import com.sky.utils.AliOssUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * @author 逐梦苍穹 * @date 2023/10/11 9:44 */ @Configuration @Slf4j public class OssConfiguration { /** * 开始创建阿里云文件上传工具类对象 * @param aliOssProperties * @ConditionalOnMissingBean 确保容器里面只有一个工具对象 * @return */ @Bean @ConditionalOnMissingBean public AliOssUtil aliOssUtil(AliOssProperties aliOssProperties){ log.info("开始创建阿里云文件上传工具类对象:{}",aliOssProperties); return new AliOssUtil(aliOssProperties.getEndpoint(),aliOssProperties.getAccessKeyId(),aliOssProperties.getAccessKeySecret(),aliOssProperties.getBucketName()); } } 3.4、注意这里有一个注意事项,就是在编写OSS配置类的时候,记得在方法上面加上@ConditionalOnMissingBean注解,这是保证项目运行过程中只会创建一次工具类对象。 @ConditionalOnMissingBean 是 Spring Boot 中的一个条件注解,它的作用是在特定的 bean 不存在时才会生效。这个注解通常用于配置类或者自动配置类中,用来根据条件来决定是否创建一个特定的 bean。 当一个 bean 被 @ConditionalOnMissingBean 注解标记时,Spring 容器会首先检查是否已经存在该类型的 bean。如果不存在,则会创建该 bean;如果已经存在,则不会创建该 bean。这样可以确保当某个特定的 bean 还未被用户自定义配置时,自动配置类会创建这个 bean。 这个注解允许您在自定义 bean 的同时,保留自动配置类提供的默认实现。这在需要覆盖默认实现时非常有用,可以确保只有在用户没有提供自定义实现时才使用默认实现。 总之,@ConditionalOnMissingBean 注解允许您根据 bean 是否存在来控制自动配置的行为。 4、图片删除上面所实现的功能中,还有一个至关重要的功能,那就是:重新上传图片的时候,需要删除原图片! 实现思路:利用redis缓存。 在数据回显的时候,把当前的访问路径存入redis缓存, 在修改完成点击保存的时候,先解析缓存中的访问路径,然后根据需要进行匹配删除 (如果是阿里云OSS存储的,直接根据这个路径删除即可;本地存储还需要先解析本地路径) 下面是具体流程步骤: 在项目当中,点击"修改"按钮,服务端后台作出数据回显: 这个方法实现的是把当前套餐的数据从数据库当中取出,并回显到前端页面。 此时利用RedisTemplate对图片路径进行缓存: 数据回显之后,点击保存的时候,调用的是服务端的"update"方法: 这部分代码不细说了。 重点是在代码开始的部分,检查图片是否被修改,如果被修改则需要删除原图片: 删除部分的代码如下(以本地文件举例): //在这里删除原图片 String deleteImage = (String) redisTemplate.opsForValue().get(KEY); if (deleteImage != null){ if (!deleteImage.equals(setmealDTO.getImage())){ //查询套餐和菜品表单的image表单项数据 List lists = deleteImageMapper.selectSetmealAndDishImage(); for (String list : lists) { if (deleteImage.equals(list)){ //正则表达式匹配文件名 String regex = "http://127.0.0.1:8080/images/(.*)"; Pattern pattern = Pattern.compile(regex); Matcher matcher = pattern.matcher(list); if (matcher.find()){ String deleteFileName = matcher.group(1); //删除图片 if (new File("E:/javaSTUDY/sky-take-out-imageFile/"+deleteFileName).delete()){ break; }else{ log.error("删除原图片失败"); } } } } } } redisTemplate.delete(KEY); |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |